package com.yangye.springclouddemorocketmq.listener;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

/**
 * @author yangye
 * @date 2020/07/15
 */
//@Component
//@RocketMQMessageListener(consumerGroup = "xxx", topic = "test-topic")
public class RocketConsumer2 implements RocketMQListener<String> {


	@Override
	public void onMessage(String message) {
		System.out.println("consumer2接收到消息：" + message);
	}
}
